﻿//using common;
//using Letter.IO;
//using System;
//using System.Threading;

//namespace tcp_text_2
//{
//    internal class ClientConnection : AConnection
//    {
//        public override string Name => "客户端";

//        public override void OnConnectionActive(ISession<Data> session)
//        {
//            base.OnConnectionActive(session);

//            int index = 0;
//            Thread thread = new Thread(() =>
//            {
//                while (true)
//                {
//                    Console.ReadLine();
//                    for (int i = 0; i < 10; i++)
//                    {
//                        session.Write(new Data() { Id = index });
//                        session.Flush();
//                        index++;
//                    }
//                }

//            });
//            thread.IsBackground = true;
//            thread.Start();
//        }
//    }
//}
